//package com.example.listener;
//
//import org.apache.pulsar.client.api.Consumer;
//import org.apache.pulsar.client.api.Message;
//import org.apache.pulsar.client.api.PulsarClientException;
//
//
///**
// * @author Administrator
// */
//@PulsarListener(sourceName = "default",
//        topics = {"test-topic2"},
//        threadPool = @ThreadPool(
//                coreThreads = 2,
//                maxCoreThreads = 3,
//                threadPoolName = "test-thread-pool"))
//public class ConsumerListener extends BaseMessageListener {
//
//    /**
//     * 消费消息
//     *
//     * @param consumer 消费者
//     * @param msg      消息
//     */
//    @Override
//    protected void doReceived(Consumer<String> consumer, Message<String> msg) {
//        try {
//            consumer.acknowledge(msg);
//        } catch (PulsarClientException e) {
//            e.printStackTrace();
//        }
//    }
//
//
//    /***
//     * 是否开启异步消费
//     * @return {@link Boolean }
//     **/
//    @Override
//    public Boolean enableAsync() {
//        return Boolean.TRUE;
//    }
//}
